package scheduler

import (
	"go-fox-edge-persist/entityAdapter"
)

var (
	valueScheduler           *RedisListValueScheduler
	recordScheduler          *RedisListRecordScheduler
	manageScheduler          *RedisListManageScheduler
	taskScheduler            *PersistManageScheduler
	DeviceHistoryAdapter     entityAdapter.IDeviceHistoryAdapter
	OperateRecordAdapter     entityAdapter.IOperateRecordAdapter
	DeviceRecordAdapter      entityAdapter.IDeviceRecordAdapter
	DeviceSequenceAdapter    entityAdapter.IDeviceSequenceAdapter
	DeviceValueRecordAdapter entityAdapter.IDeviceValueRecordAdapter
)

func init() {
	valueScheduler = &RedisListValueScheduler{}
	recordScheduler = &RedisListRecordScheduler{}
	manageScheduler = &RedisListManageScheduler{}
}

// Scheduler 线程函数
func Scheduler() {
	taskScheduler.Scheduler()
	valueScheduler.Scheduler()
	recordScheduler.Scheduler()
	manageScheduler.Scheduler()
}
